package cn.com.wind.bdg.polish.polish.service;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
 * 
 * @ClassName:  PollContentFKafka   
 * @Description:从kafka上拉取原始网页信息  
 * @author: gaoxiang
 * @date:   2020年8月19日 下午1:55:21
 */
@Service
public class PollContentFKafka {
	@Autowired
	private KafkaService kafkaService;
	public void pollKafka() {
		kafkaService.init();
		List<String> list = kafkaService.consume();
	}
}
